package com.holly.unit.kafka.model;

import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;

/**
 * 获取kafka发送消息的回调状态
 * @author pengpeng
 *
 */
@FunctionalInterface
public interface CallbackSendMessage {
	
	/**
	 * 回调获取发送消息状态
	 * @param messageList
	 * @param kafkaConsumer
	 * @param isNoStop
	 */
	void sendMessageStatus(List<Kmessage> messageList,Object kafkaConsumer,AtomicBoolean isNoStop);

}
